/**
 * @file
 * @brief Implementation of global websocket functions.
 * @author Kirill Neznamov <kirill.neznamov@dsr-corporation.com>
 * @date May 2022
 * @copyright SPDX-License-Identifier: GPL-2.0-or-later WITH GCC-exception-2.0
 */
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <libwebsockets.h>
#include "websocket-global.h"
#include "bacnet/basic/sys/debug.h"

static pthread_mutex_t websocket_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER;
static pthread_mutex_t websocket_dispatch_mutex = PTHREAD_RECURSIVE_MUTEX_INITIALIZER;

#if (BSC_DEBUG_WEBSOCKET_MUTEX_ENABLED != 1)

void bsc_websocket_global_lock(void)
{
  pthread_mutex_lock(&websocket_mutex);
}

void bsc_websocket_global_unlock(void)
{
  pthread_mutex_unlock(&websocket_mutex);
}

void bws_dispatch_lock(void)
{
  pthread_mutex_lock(&websocket_dispatch_mutex);
}

void bws_dispatch_unlock(void)
{
  pthread_mutex_unlock(&websocket_dispatch_mutex);
}

#else
static int volatile websocket_mutex_cnt = 0;
static int volatile websocket_dispatch_mutex_cnt = 0;

void bsc_websocket_global_lock_dbg(char *f, int line)
{
  printf("bsc_websocket_global_lock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f, line, websocket_mutex_cnt, pthread_self());
  websocket_mutex_cnt++;
  fflush(stdout);
  pthread_mutex_lock(&websocket_mutex);
  printf("bsc_websocket_global_lock_dbg() <<< lock_cnt %d tid = %ld\n", websocket_mutex_cnt, pthread_self());
  fflush(stdout);
}

void bsc_websocket_global_unlock_dbg(char *f, int line)
{
  printf("bsc_websocket_global_unlock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f, line, websocket_mutex_cnt, pthread_self());
  websocket_mutex_cnt--;
  fflush(stdout);
  pthread_mutex_unlock(&websocket_mutex);
  printf("bsc_websocket_global_unlock_dbg() <<< lock_cnt %d tid = %ld\n", websocket_mutex_cnt, pthread_self());
  fflush(stdout);
}

void bws_dispatch_lock_dbg(char *f, int line)
{
  printf("bws_dispatch_lock_dbg() >>> %s:%d lock_cnt %d tid = %ld\n", f, line, websocket_dispatch_mutex_cnt, pthread_self());
  websocket_dispatch_mutex_cnt++;
  fflush(stdout);
  pthread_mutex_lock(&websocket_dispatch_mutex);
  printf("bws_dispatch_lock_dbg() <<< lock_cnt %d tid = %ld\n", websocket_dispatch_mutex_cnt, pthread_self());
  fflush(stdout);
}

void bws_dispatch_unlock_dbg(char *f, int line)
{
  printf("bws_dispatch_unlock_dbg() >>> %s:%d lock_cnt %d  tid = %ld\n", f, line, websocket_dispatch_mutex_cnt, pthread_self());
  websocket_dispatch_mutex_cnt--;
  fflush(stdout);
  pthread_mutex_unlock(&websocket_dispatch_mutex);
  printf("bws_dispatch_unlock_dbg() <<< lock_cnt %d tid = %ld\n", websocket_dispatch_mutex_cnt, pthread_self());
  fflush(stdout);
}

#endif

static bool bsc_websocket_log_initialized = false;

void bsc_websocket_init_log(void)
{
    bsc_websocket_global_lock();
    if(!bsc_websocket_log_initialized) {
      bsc_websocket_log_initialized = true;
#if DEBUG_LIBWEBSOCKETS_ENABLED == 1
      printf("LWS_MAX_SMP = %d", LWS_MAX_SMP);
      lws_set_log_level(LLL_ERR | LLL_WARN | LLL_NOTICE | LLL_INFO | LLL_DEBUG |
            LLL_PARSER | LLL_HEADER | LLL_EXT | LLL_CLIENT | LLL_LATENCY |
            LLL_USER | LLL_THREAD,
        NULL);
#else
      lws_set_log_level(0, NULL);
#endif
    }
    bsc_websocket_global_unlock();
}
